package com.example.rabbitmq;

/**
 * 常量类
 */
public class Constants {
    //消费者确认
    public final static String ACK_QUEUE = "ack.queue";
    public final static String ACK_EXCHANGE = "ack.exchange";
    //发送方确认
    public final static String CONFIRM_EXCHANGE = "confirm.exchange";
    public final static String CONFIRM_QUEUE = "confirm.queue";
    //回退
    public final static String RETURN_EXCHANGE = "return.exchange";
    public final static String RETURN_QUEUE = "return.queue";
    //重试
    public final static String RETRY_EXCHANGE = "retry.exchange";
    public final static String RETRY_QUEUE = "retry.queue";
    //TTL
    public final static String TTL_EXCHANGE = "ttl.exchange";
    public final static String TTL_QUEUE = "ttl.queue";
    public final static String TTL_EXCHANGE2 = "ttl.exchange2";
    public final static String TTL_QUEUE2 = "ttl.queue2";
    //死信和正常队列
    public final static String DLX_EXCHANGE = "dlx.exchange";
    public final static String DLX_QUEUE = "dlx.queue";
    public final static String NORMAL_EXCHANGE = "normal.exchange";
    public final static String NORMAL_QUEUE = "normal.queue";
    //延迟
    public final static String DELAY_QUEUE = "delay.queue";
    public final static String DELAY_EXCHANGE = "delay.exchange";
    //限流
    public final static String QOS_QUEUE = "qos.queue";
    public final static String QOS_EXCHANGE = "qos.exchange";
    //仲裁
    public final static String QUORUM_QUEUE = "quorum.queue";
    public final static String QUORUM_EXCHANGE = "quorum.exchange";
    //集群（使用haproxy）
    public final static String CLUSTER_QUEUE = "cluster.queue";


}
